package com.majun.util;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * <p> Description: websocket 工具类 </p>
 * <p> Title: WebSocketConnectManager </p>
 * <p> Create Time: 2019/10/15 16:32 </p>
 *
 * @author zhongzhipeng
 * @since 1.0
 */
public class WebSocketUtil {

    /** 存储在线连接总数 */
    private static AtomicInteger onlineConnectCount = new AtomicInteger(0);

    /** 获取在线连接总数 */
    public static AtomicInteger getOnlineConnectCount() {
        return onlineConnectCount;
    }

    /** 获取在线连接总数 */
    public static int getOnlineConnectCountOfInt() {
        return Math.max(onlineConnectCount.get(), 0);
    }

    /**
     * 是否存在websocket 在线连接
     *
     * @return 存在返回 true 不存在返回 false
     */
    public static boolean existsConnect() {
        return getOnlineConnectCountOfInt() > 0;
    }
}
